home
***
CD-ROM
|
disk
|
FTP
|
other
***
search
/
Aminet 25
/
Aminet 25 (1998)(GTI - Schatztruhe)[!][Jun 1998].iso
/
Aminet
/
comm
/
net
/
AMarquee1_48.lha
/
AMarquee
/
examples
/
amarqueedebug.c
< prev
next >
Wrap
C/C++ Source or Header
|
1998-04-10
|
7KB
|
183 lines
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <dos/dos.h>
#include <clib/dos_protos.h>
#include <clib/exec_protos.h>
#include <clib/AMarquee_protos.h>
#include <pragmas/AMarquee_pragmas.h>
struct Library * AMarqueeBase = NULL;
struct QSession * session = NULL;
/* Takes user input until blank line is typed */
void ProcessDebugCommands(struct QSession * session)
{
while(1)
{
char debugline[500] = "\0\0\0\0\0\0\0\0";
char * keyword, * data;
ULONG dataLen = 0L;
LONG res;
printf("Enter your debug command now: "); fflush(stdout);
gets(debugline);
keyword = &debugline[2];
if (data = strchr(keyword,'='))
{
*data = '\0'; /* terminate the keyword */
data++;
dataLen = strlen(data)+1;
}
switch((int)(debugline[0]))
{
case '\0': res=QGo(session,0L); break;
case 'A': res=QSetMessageAccessOp(session, keyword, -1); break;
case 'm': res=QMessageOp(session, keyword, data, dataLen); break;
case 'M': res=QSysMessageOp(session, keyword, data); break;
case 'a': res=QSetAccessOp(session, keyword); break;
case 's': res=QSetOp(session, keyword, data, dataLen); break;
case 'S': res=QStreamOp(session, keyword, data, dataLen); break;
case 'r': res=QRenameOp(session, keyword, data); break;
case 'D': res=QDebugOp(session, keyword); break;
case 'g': res=QGetOp(session, keyword, -1); break;
case 'd': res=QDeleteOp(session, keyword); break;
case 'i': res=QInfoOp(session); break;
case 'c': res=QSubscribeOp(session, keyword, -1); break;
case 'C': res=QGetAndSubscribeOp(session, keyword, -1); break;
case 'k': res=QClearSubscriptionsOp(session,atoi(keyword)); break;
case 'p': res=QPingOp(session); break;
case 'v': res=QRequestPrivilegesOp(session,atol(keyword)); break;
case 'w': res=QReleasePrivilegesOp(session,atol(keyword)); break;
case '!': res=QKillClientsOp(session,keyword); break;
case '?': res=QGetParameterOp(session,keyword); break;
case '$': res=QSetParameterOp(session,keyword,data); break;
default: printf("Command code %c was not recognized.\n",debugline[0]); break;
}
printf("(Op result was %i)\n",res);
if (debugline[0] == '\0') return;
}
}
void CleanExit(void)
{
printf("\nCleaning up...\n");
if (session) QFreeSession(session); /* This MUST be done before we close the library! */
if (AMarqueeBase) CloseLibrary(AMarqueeBase);
printf("All done.\n");
}
/* Main program */
int main(int argc, char ** argv)
{
char * connectTo, * progName;
int port;
printf("Usage Note: AMarqueeDebug [hostname=localhost] [myname=debug] [port=2957]\n");
atexit(CleanExit);
connectTo = (argc>1) ? argv[1] : "localhost";
progName = (argc>2) ? argv[2] : "debug";
port = (argc>3) ? atoi(argv[3]) : 2957;
if ((AMarqueeBase = OpenLibrary("amarquee.library",46L)) == NULL)
{
printf("Couldn't open amarquee.library v46!\n");
exit(RETURN_ERROR);
}
printf("Connecting to %s:%i\n",connectTo, port);
#ifdef ASYNC_CONNECT
if ((session = QNewSessionAsync(connectTo, port, progName)) == NULL)
{
printf("Couldn't connect to server %s:%i\n",connectTo, port);
exit(RETURN_WARN);
}
#else
if ((session = QNewSession(connectTo, port, progName)) == NULL)
{
printf("Couldn't connect to server %s:%i\n",connectTo, port);
exit(RETURN_WARN);
}
#endif
printf("Connected to server %s:%i\n",connectTo, port);
#ifdef WANT_INSTANT_SAMPLE_DATA
/* Setup some sample data */
(void)QSetOp(session, "sampledata", "Kids", 5);
(void)QSetOp(session, "sampledata/Jeremy", "1", 2);
(void)QSetOp(session, "sampledata/Joanna", "2", 2);
(void)QSetOp(session, "sampledata/Joanna/nerd", "yep! :)", 8);
(void)QSetOp(session, "sampledata/Joellen", "3", 2);
(void)QSetOp(session, "sampledata/Charcoal", "Kitty!", 7);
(void)QGo(session, 0L);
#endif
printf("Commands are:\n");
printf("\n");
printf("a wildhostpath Access control (default is /#?/#?)\n");
printf("A wildhostpath Access control for incoming messages (default in no access)\n");
printf("m hosts=data Send an active message to hosts\n");
printf("M hosts=string Send an system message to hosts\n");
printf("s path=data Set data node value\n");
printf("S path=data Stream data node value\n");
printf("r path=newlabel Rename data node\n");
printf("D debugstring Send debug string\n");
printf("g wildpath Get a node or nodes\n");
printf("c wildpath Subscribe to a node or nodes\n");
printf("C wildpath Get&Subscribe to a node or nodes\n");
printf("k opID Klear subscriptions (by id or 0 for all)\n");
printf("d wildpath Delete a node or nodes\n");
printf("i Request info packet\n");
printf("p Request ping packet\n");
printf("v # Request new privileges (by code bitchord)\n");
printf("w # Release existing privileges (by code bitchord)\n");
printf("! hosts Kill other clients (requires KILLCLIENTS privilege!)\n");
printf("$ param=string Set a parameter with QSetParam()\n");
printf("? param Get a parameter by name\n");
printf("<enter> Send accumulated transactions (GO!!)\n");
printf("\n");
printf("Press CTRL-F to enter commands, or CTRL-C to quit\n");
while(1)
{
struct QMessage * qMsg;
ULONG signals = (1L << session->qMsgPort->mp_SigBit) | (SIGBREAKF_CTRL_C) | (SIGBREAKF_CTRL_F);
/* Wait for next message from the server */
signals = Wait(signals);
if (signals & (1L << session->qMsgPort->mp_SigBit))
{
while(qMsg = (struct QMessage *) GetMsg(session->qMsgPort))
{
struct QRunInfo * inf = (qMsg->qm_DataLen == sizeof(struct QRunInfo)) ? ((struct QRunInfo *) qMsg->qm_Data) : NULL;
/* Handle message */
printf("Message %p recieved---------\n",qMsg);
printf("Status: %i (%s)\n", qMsg->qm_Status, QErrorName(qMsg->qm_Status));
printf("Error Line: %i\n", qMsg->qm_ErrorLine);
printf("Message ID: %i\n", qMsg->qm_ID);
printf("Path: [%s]\n", qMsg->qm_Path?qMsg->qm_Path:"<NULL>");
printf("Data: [%s](int=%i)\n", qMsg->qm_Data?qMsg->qm_Data:((UBYTE*)"<NULL>"),qMsg->qm_Data?(*((int*)qMsg->qm_Data)):0);
printf("DataLen: %lu\n", qMsg->qm_DataLen);
printf("ActualLen: %lu\n", qMsg->qm_ActualLen);
if (inf) printf("Info: alloced:%li allowed:%li avail:%li curPrivs=0x%x posPrivs=0x%x\n",
inf->qr_Alloced, inf->qr_Allowed, inf->qr_Avail, inf->qr_CurrentPrivs, inf->qr_PossiblePrivs);
FreeQMessage(session, qMsg);
}
}
if (signals & SIGBREAKF_CTRL_F) ProcessDebugCommands(session);
if (signals & SIGBREAKF_CTRL_C) break; /* Quit if CTRL-C pressed */
}
/* CleanExit() called here! */
}